package impl

import (
	"entry_task/entry_core/src/db"
	"fmt"
	"sync"
)

var initialized = false

func init() {
	fmt.Println("hello,init db")
	if initialized {
		return
	}
	//初始化数据库连接管理器
	dbSourceManager := &dbSourceManagerImpl{
		dbSourceMap: &sync.Map{},
	}
	db.InjectDbSourceManager(dbSourceManager)
	InitDbSources()
	initialized = true
}

/**
多数据源时，可采用遍历的方式
*/
func InitDbSources() {
	db.DbSourceManager().AddDbSource("mysql")
}
